home *** CD-ROM | disk | FTP | other *** search
/ Reverse Code Engineering RCE CD +sandman 2000 / ReverseCodeEngineeringRceCdsandman2000.iso / RCE / Ebooks / Thinking in Java / c15 / MultiJabberClient.java < prev    next >
Encoding:
Java Source  |  2000-05-25  |  4.5 KB  |  129 lines
  1. //: MultiJabberClient.java
  2. //////////////////////////////////////////////////
  3. // Copyright (c) Bruce Eckel, 1998
  4. // Source code file from the book "Thinking in Java"
  5. // All rights reserved EXCEPT as allowed by the
  6. // following statements: You can freely use this file
  7. // for your own work (personal or commercial),
  8. // including modifications and distribution in
  9. // executable form only. Permission is granted to use
  10. // this file in classroom situations, including its
  11. // use in presentation materials, as long as the book
  12. // "Thinking in Java" is cited as the source. 
  13. // Except in classroom situations, you cannot copy
  14. // and distribute this code; instead, the sole
  15. // distribution point is http://www.BruceEckel.com 
  16. // (and official mirror sites) where it is
  17. // freely available. You cannot remove this
  18. // copyright and notice. You cannot distribute
  19. // modified versions of the source code in this
  20. // package. You cannot use this file in printed
  21. // media without the express permission of the
  22. // author. Bruce Eckel makes no representation about
  23. // the suitability of this software for any purpose.
  24. // It is provided "as is" without express or implied
  25. // warranty of any kind, including any implied
  26. // warranty of merchantability, fitness for a
  27. // particular purpose or non-infringement. The entire
  28. // risk as to the quality and performance of the
  29. // software is with you. Bruce Eckel and the
  30. // publisher shall not be liable for any damages
  31. // suffered by you or any third party as a result of
  32. // using or distributing software. In no event will
  33. // Bruce Eckel or the publisher be liable for any
  34. // lost revenue, profit, or data, or for direct,
  35. // indirect, special, consequential, incidental, or
  36. // punitive damages, however caused and regardless of
  37. // the theory of liability, arising out of the use of
  38. // or inability to use software, even if Bruce Eckel
  39. // and the publisher have been advised of the
  40. // possibility of such damages. Should the software
  41. // prove defective, you assume the cost of all
  42. // necessary servicing, repair, or correction. If you
  43. // think you've found an error, please email all
  44. // modified files with clearly commented changes to:
  45. // Bruce@EckelObjects.com. (Please use the same
  46. // address for non-code errors found in the book.)
  47. /////////////////////////////////////////////////
  48.  
  49. // Client that tests the MultiJabberServer
  50. // by starting up multiple clients.
  51. import java.net.*;
  52. import java.io.*;
  53.  
  54. class JabberClientThread extends Thread {
  55.   private Socket socket;
  56.   private BufferedReader in;
  57.   private PrintWriter out;
  58.   private static int counter = 0;
  59.   private int id = counter++;
  60.   private static int threadcount = 0;
  61.   public static int threadCount() { 
  62.     return threadcount; 
  63.   }
  64.   public JabberClientThread(InetAddress addr) {
  65.     System.out.println("Making client " + id);
  66.     threadcount++;
  67.     try {
  68.       socket = 
  69.         new Socket(addr, MultiJabberServer.PORT);
  70.     } catch(IOException e) {
  71.       // If the creation of the socket fails, 
  72.       // nothing needs to be cleaned up.
  73.     }
  74.     try {    
  75.       in = 
  76.         new BufferedReader(
  77.           new InputStreamReader(
  78.             socket.getInputStream()));
  79.       // Enable auto-flush:
  80.       out = 
  81.         new PrintWriter(
  82.           new BufferedWriter(
  83.             new OutputStreamWriter(
  84.               socket.getOutputStream())), true);
  85.       start();
  86.     } catch(IOException e) {
  87.       // The socket should be closed on any 
  88.       // failures other than the socket 
  89.       // constructor:
  90.       try {
  91.         socket.close();
  92.       } catch(IOException e2) {}
  93.     }
  94.     // Otherwise the socket will be closed by
  95.     // the run() method of the thread.
  96.   }
  97.   public void run() {
  98.     try {
  99.       for(int i = 0; i < 25; i++) {
  100.         out.println("Client " + id + ": " + i);
  101.         String str = in.readLine();
  102.         System.out.println(str);
  103.       }
  104.       out.println("END");
  105.     } catch(IOException e) {
  106.     } finally {
  107.       // Always close it:
  108.       try {
  109.         socket.close();
  110.       } catch(IOException e) {}
  111.       threadcount--; // Ending this thread
  112.     }
  113.   }
  114. }
  115.  
  116. public class MultiJabberClient {
  117.   static final int MAX_THREADS = 40;
  118.   public static void main(String[] args) 
  119.       throws IOException, InterruptedException {
  120.     InetAddress addr = 
  121.       InetAddress.getByName(null);
  122.     while(true) {
  123.       if(JabberClientThread.threadCount() 
  124.          < MAX_THREADS)
  125.         new JabberClientThread(addr);
  126.       Thread.currentThread().sleep(100);
  127.     }
  128.   }
  129. } ///:~